package yuekao6.dws;

public class StorageClickHouse {
    public static void main(String[] args) {
        //（5）实时数仓DWS层-统计当日各机构的分拣次数，并补充城市、省份等维度信息，写入ClickHouse对应表，环境准备，从 Kafka tms_dwd_bound_sort
        // 主题读取数据，转换数据结构，设置水位线，按照机构 ID 分组，开窗，引入触发器，聚合，关联维度信息，获取城市 ID，写入到 ClickHouse（5分）

    }
}
